<?php
/**
 * redis扩展订阅
 */
set_time_limit(0);
ini_set('default_socket_timeout',-1);

 try{
    $redis = new Redis();
    $redis->pconnect('redis-db',6379);
    $redis->psubscribe(array('psubscribe'=>'ch*'),function($redis,$machestr,$chn,$message){
        echo "------\n";
        var_dump($redis);
        var_dump($machestr);
        var_dump($chn);
        var_dump($message);
    });
    $redis->close();
    echo ".....\n";
}catch(Exception $e){
    echo $e->getMessage();
}